package org.niit.controller

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.AdClickData
import org.niit.service.ZhangTimeService

class ZhangTimeController {

  val zhangTimeService = new ZhangTimeService

  def dispatch(data:DStream[AdClickData]): Unit ={

    //调用相应的Service模块
    zhangTimeService.dataAnalysis(data)

  }

}
